package cn.wanda.modes.streaming

import cn.wanda.modes.GenericMethod
import cn.wanda.topologies.bases.{SparkStreamingTopology, SparkTopology}


object SparkStreaming {






  def main(args: Array[String]): Unit = {


    GenericMethod.initialize[SparkStreamingTopology](args, "Spark-Streaming")



  }


}
